package com.oh.core.server.initializer;

import com.oh.core.server.handler.ServerHandler;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
import io.netty.handler.codec.bytes.ByteArrayDecoder;
import io.netty.handler.codec.bytes.ByteArrayEncoder;
import io.netty.handler.timeout.IdleStateHandler;
import org.springframework.stereotype.Component;

import java.util.concurrent.TimeUnit;

import javax.annotation.Resource;


/**
 * Socket 初始化器，每一个Channel进来都会调用这里的 InitChannel 方法
 * 通用处理，通过byte数组传递消息头和消息体
 */
@Component
public class ServerInitializer extends ChannelInitializer<SocketChannel> {

//    @Resource
//    SecurityHandler securityHandler;

    @Resource
    ServerHandler serverHandler;

    @Override
    protected void initChannel(SocketChannel socketChannel) throws Exception {
        ChannelPipeline pipeline = socketChannel.pipeline();
        //用户每次请求都会从第一个Handler开始
        //设置超时时间
        pipeline.addLast(new IdleStateHandler(30, 30, 60, TimeUnit.SECONDS));
        // 消息解码: 截取消息体，消息头和消息体 第5个参数（长度）从第7个byte开始，4个报文长度
        pipeline.addLast(new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 7, 4, 0, 0));
        // 添加对byte数组的编解码，netty提供了很多编解码器，你们可以根据需要选择
        pipeline.addLast(new ByteArrayDecoder());
        pipeline.addLast(new ByteArrayEncoder());
        // 添加上自己的处理器
        pipeline.addLast(serverHandler);
    }

}
